package com.shujia.userprofile.info.social

import com.shujia.util.SparkRunner
import org.apache.spark.sql.{DataFrame, SparkSession}

object AddressUserTag extends SparkRunner {
  fieldName = "address"

  override def fetchTgg(spark: SparkSession, ds: String): DataFrame = {

    spark.sql(
      s"""
         |select
         | member_id as id,
         | address
         | from
         |dim.dim_pub_user_addr_d_f
         |where ds='$ds'
         |
         |""".stripMargin)
  }
}
